package com.baic.ibase.service.mqtt.impl;


import com.baic.ibase.service.mqtt.MqttSendGateway;
import com.baic.ibase.service.mqtt.MqttSendService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MqttSendServiceImpl implements MqttSendService {

    @Autowired
    private MqttSendGateway mqttSendGateway;


    @Override
    public void send(String topic, String message) {
        mqttSendGateway.send(topic, message);
    }

    @Override
    public void send(String topic, int qos, String message) {
        mqttSendGateway.send(topic, qos, message);
    }

    @Override
    public void send(String topic, int qos, boolean retained, String message) {
        mqttSendGateway.send(topic, qos, retained, message);
    }

    @Override
    public void send(String topic, byte[] message) {
        mqttSendGateway.send(topic, message);
    }

    @Override
    public void send(String topic, int qos, byte[] message) {
        mqttSendGateway.send(topic, qos, message);
    }

    @Override
    public void send(String topic, int qos, boolean retained, byte[] message) {
        mqttSendGateway.send(topic, qos, retained, message);
    }
}
